package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.offline.pojo.LoadDataParam;

import java.io.Serializable;
import java.util.List;

/**
 * 将原查询切分为批次的查询
 * @author 沈东生
 */
public interface DataBatchService extends Serializable{
    /**
     * 最大的批次大小，hashtid最大有32个分区
     */
    int MAX = 32;
    /**
     * 将原查询切分为批次的查询
     * @param param
     * @return
     */
    List<LoadDataParam> createBatch(LoadDataParam param);
}
